package com.carpedil.redis.queue;

import java.util.concurrent.ArrayBlockingQueue;

/** @author Administrator */
public class QueueMainThread {

  public static void main(String[] args) {
    ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<String>(5);
    InThread in1 = new InThread(queue);

    new Thread(in1).start();
    new OutThread(queue).start();
    new OutThread(queue).start();
    new OutThread(queue).start();
  }
}
